package com.spark3;

import org.apache.spark.sql.SparkSession;

public class MainTest03 {

    public static void main(String[] args) {

        System.out.println("使用java代码测试spark-sql查询。。。");

        SparkSession spark = SparkSession
                .builder()
                .enableHiveSupport()
                .getOrCreate();

        spark.sql("select * from default.zhuzh_livy_test_003").show(false);

        spark.stop();
    }
}
